 var mysql      = require('mysql');
// var connection = mysql.createConnection({
//   host     : 'localhost',
//   user     : 'root',
//   password : '123456',
//   port:'3307',
//   database : 'mysql'
// });
//
// module.exports=connection;
//连接池
var pool = mysql.createPool({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  port:'3306',
  database : 'datadb',
});
var query=function(sql,callback){
  pool.getConnection(function(err,conn){
    if(err){
      callback(err,null);
    }else{
      conn.query(sql,function(err,results){
        //释放连接
        conn.release();
        //事件驱动回调
        callback(err,results);
      });
    }
  });
};

module.exports=query;
